package functions;


import com.alibaba.fastjson.JSON;
import org.apache.avro.data.Json;
import org.apache.flink.api.common.functions.MapFunction;
import pojo.LogBean;

public class JsontoBeanFunction   implements MapFunction<String, LogBean> {
    @Override
    public LogBean map(String s) throws Exception {
        LogBean logBean = JSON.parseObject(s, LogBean.class);
        return  logBean;

    }
}
